const mysql = require('mysql')

// 创建数据池
const pool = mysql.createPool({
    host: '47.92.199.203', // 数据库地址
    user: 'root', // 数据库用户
    password: 'ZZM+zn=1314', // 数据库密码
    database: 'LJL-shop' // 选中数据库
})

const db_query = (sql, params) => {
    return new Promise(function (res, rej) {
        // 在数据池中进行会话操作
        pool.getConnection(function (err, connection) {
            if(err) return rej(err)
            connection.query(sql, (error, results) => {

                // 结束会话
                connection.release();

                // 如果有错误就抛出
                if (error) return rej(error);
                return res(results)
            })
        })

    })
}
module.exports = db_query